package org.zhadoop.stream.api.opereators.serdes;

import org.zhadoop.stream.api.ConfigAnnotation;
import org.zhadoop.stream.api.StreamSerDeAnnoation;
import org.zhadoop.streaming.config.StreamingConfig;
import org.zhadoop.streaming.serde.SimpleSerDe;

/**
 * 一个很简单的，根据分隔符来确定文件序列化和反序列化的API
 * 
 * 数据的反序列化
 * 
 * @author zwd
 *
 */
@StreamSerDeAnnoation(SimpleSerDe.class)
public class SimpleSerDeAPI extends SerDeAPI {
	
	@ConfigAnnotation(StreamingConfig.SERDE_SIMPLESERDE_SEPARATOR)
	private String separator;
	
	@ConfigAnnotation(StreamingConfig.STREAMING_OPERATOR_TIMEZONE)
	private String timezoneForTimestamp;

	public String getSeparator() {
		return separator;
	}

	public void setSeparator(String separator) {
		this.separator = separator;
	}

	public String getTimezoneForTimestamp() {
		return timezoneForTimestamp;
	}

	public void setTimezoneForTimestamp(String timezoneForTimestamp) {
		this.timezoneForTimestamp = timezoneForTimestamp;
	}
}
